package com.liuyi.netty.im.server.handle.cluster;

import com.liuyi.netty.im.commons.codes.data.DataEvent;
import io.netty.channel.Channel;
import io.netty.channel.ChannelId;

import java.util.List;

/**
 * 集群消息接收处理
 *
 * @author Mr.Fmy
 * @since 2021/12/25
 */
public interface ClusterMessageDispose {

    /**
     * 获取发送该消息需要的 {@link ChannelId}
     * @return 如果返回未 NULL 则证明发送不了该消息，否则则可以接收该消息并发送
     */
    List<Channel> dispose(DataEvent data);
}
